import cn.hutool.core.lang.Console;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;

/**
 * 马场
 *
 * @author <achao1441470436@gmail.com>
 * @since 2021/11/4 0004 23:37
 */
public class Racecourse implements SinkFunction<HorseTicket> {
    private static final long serialVersionUID = 7327454374125251434L;

    @Override
    public void invoke(HorseTicket horseTicket, Context context) throws Exception {
        Console.error("{} is driving horse!And his scores are {}.", horseTicket.getUsername(), horseTicket.getScores());
    }
}
